package com.aloda.ai;

import com.aloda.dto.AiGenerateResultDTO;
import com.aloda.dto.AiMessageDTO;
import com.aloda.dto.FlowableData;
import io.reactivex.Flowable;

/**
 * AI业务处理层
 */
public interface AiPlatform {

    /**
     * 处理同步调用请求
     * @param aiMessageDTO
     * @return
     */
    AiGenerateResultDTO doSyncRequest(AiMessageDTO aiMessageDTO);

    /**
     * 处理流式调用请求
     * @param aiMessageDTO
     * @return
     */
    Flowable<FlowableData> doStreamRequest(AiMessageDTO aiMessageDTO);
}
